package com.bdqn.spark.chapter05

import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.rdd.RDD

object Spark02_RDD_File_Par1 {
  def main(args: Array[String]): Unit = {
    val conf: SparkConf = new SparkConf()
      .setMaster("local[*]")
      .setAppName("RDD-File")
    val sc: SparkContext = new SparkContext(conf)

    val fileSourceRDD: RDD[String] =
      sc.textFile("input/2.txt",2)

    // 14 / 2 = 7

    // 分区数：2个
    // 第一个分区：7
    // 0 -》 [0,7]  => 1234567@@
    // 第二个分区：7
    // 1 -> [7,14]  => 89@@0

    // 1234567@@
    // 012345678

    // 89@@
    // 9101112

    // 0
    // 13

    fileSourceRDD.saveAsTextFile("output")


    sc.stop()
  }
}
